/*
 *@Description: 操作数据库方法
 *@Author:  lupan
 *@Date: 2019-07-14 14:04:20
*/
const mysql = require('mysql');
const config = require('../config/index')

const pool = mysql.createPool(config.db);

// 连接公用方法
function query (sql, options, callback) {
  return new Promise((resolve, reject) => {
    pool.getConnection((err, conn) => {
      if (err) {
        reject('Error：' + err)
      } else{
        conn.query(sql,(err, results, fields)  => {
          //释放连接  
          if (err) {
            reject('Error：' + err)
          } else {
            resolve(results)
          }
          conn.release()
        })
      }
    })
  })
}

module.exports = query